package pwd.allen.spring.consumer;

/**
 * @author 门那粒沙
 * @create 2020-04-06 9:00
 **/
public class Listener {
    //具体执行业务的方法
    public void listen(Object msg) {
        if (msg instanceof byte[]) {
            // 如果消息没有content_type=text/plain，则msg为byte[]，需要转换
            msg = new String((byte[]) msg);
        }
        System.out.println("\n消费者B开始处理消息： " + msg + "\n");
    }
}
